package com.icesoft.xsnow.mq.consumer.listener;

import lombok.extern.slf4j.Slf4j;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.stereotype.Service;

/**
 * @program: xsnow
 * @description: 消息监听
 * @author: xuefeng.gao
 * @create: 2019-07-23 15:45
 **/
@Service
@Slf4j
public class MessageListener {

    @StreamListener("input")
    public void recevieMsg(String receiveMsg){
        log.info("====Input 消费消息===="+receiveMsg);
    }


/*
    @StreamListener("input2")
    public void recevieMsg2(String receiveMsg){
        log.debug("====Input2 消费消息===="+receiveMsg);
    }*/
}
